package com.iot.core.receiver;

import com.iot.core.base.IotMessage;
import com.iot.core.base.IotSubTopic;
import org.springframework.scheduling.annotation.Async;

/**
 * @auther 王霄
 * @date 2022/7/28 10:54
 */
public interface BaseReceiver {
    IotSubTopic getSubTopic();

    @Async
    void receive(IotMessage iotMessage);
}
